package producer_consumer;

import java.util.concurrent.ArrayBlockingQueue;

public class Test1 {
	public static void main(String[] args) {
		ArrayBlockingQueue<Baozi> abq = new ArrayBlockingQueue<>(2);
		
		Producer1 pdc = new Producer1(abq);
		Consumer1 c = new Consumer1(abq);
		/*Consumer d=new Consumer(abq);
		new Thread(d).start();*/
		
		Thread t1 = new Thread(pdc);
		Thread t2 = new Thread(c);
		t1.start();
		t2.start();
	}
}
